var mysql = require('mysql');
var dbConfig = require('./dbConfig'); 


module.exports = {
	query : function(sql,params,callback){
		// 每次使用的时候创建连接，数据操作完成之后关闭连接
		let connection = mysql.createConnection(dbConfig);
		
		connection.connect(function(err){
			if(err){
				console.log('数据库连接失败');
				callback && callback(err);
				throw err;
            }
            
        	// 开始数据操作
			connection.query(sql, params, function(err,results,fields){
				if(err){
					console.log('数据操作失败');
					callback && callback(err);
					throw err;
				}
				
				// 将查询出来的数据返回给回调函数,results=>数据操作后的结果，fields=>数据库连接的一些字段
				callback && callback(err, results&&JSON.parse(JSON.stringify(results)), fields&&JSON.parse(JSON.stringify(fields)));
				
	            // 停止链接数据库
				connection.end(function(err){
					if(err){
						console.log('关闭数据库连接失败！');
						throw err;
					}
				});
			});
		});
	}
};